package com.gitee.cnlongs.cnlongmq.server;

import com.gitee.cnlongs.cnlongmq.basic.entitiy.response.CnLongMqResponse;
import com.gitee.cnlongs.cnlongmq.server.operator.CnLongMqExecuter;
import com.gitee.cnlongs.cnlongmq.server.service.LongMqService;

/**
 * 系统名称：LongMqServer.java
 * 模块名称：
 * 模块描述：中国龙[消息队列] - 接口实现层
 * 功能列表：
 * 模块作者：ZOUYONG
 * 开发时间：2019年3月31日 下午3:14:51
 * 模块路径：com.gitee.cnlongs.cnlongmq.server.LongMqServer
 */
public class LongMqServer implements LongMqService {
	
	// MQ消息队列执行器对象
	private static CnLongMqExecuter executer;
	
	public LongMqServer(String cnlongMqConfigPath) {
		if(null == LongMqServer.executer) {
			LongMqServer.executer = new CnLongMqExecuter(cnlongMqConfigPath);
		}
	}
	
	/**
	 * 功能描述：发送mq消息
	 × 模块作者：ZOUYONG
	 × 开发时间：2019年4月12日 下午3:20:02
	 × 返回数据：String
	 * @param seqKey 消息队列Key值名称
	 * @param message 消息内容，将message转换成json格式
	 */
	public CnLongMqResponse sendLongMqMessage(String seqKey, Object message) throws Exception {
		
		return LongMqServer.executer.handlerSendLongMqMessage(seqKey, message);
	}

	public static CnLongMqExecuter getExecuter() {
		return executer;
	}

}
